[INFO] fetching crate agent-rex 0.0.0-nightly.20260308...
[INFO] testing agent-rex-0.0.0-nightly.20260308 against try#b8e88e5ddf5521a9f43ee3f62a702388c713e4bb for pr-155114
[INFO] extracting crate agent-rex 0.0.0-nightly.20260308 into /workspace/builds/worker-1-tc2/source
[INFO] started tweaking crates.io crate agent-rex 0.0.0-nightly.20260308
[INFO] finished tweaking crates.io crate agent-rex 0.0.0-nightly.20260308
[INFO] tweaked toml for crates.io crate agent-rex 0.0.0-nightly.20260308 written to /workspace/builds/worker-1-tc2/source/Cargo.toml
[INFO] validating manifest of crates.io crate agent-rex 0.0.0-nightly.20260308 on toolchain b8e88e5ddf5521a9f43ee3f62a702388c713e4bb
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b8e88e5ddf5521a9f43ee3f62a702388c713e4bb" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate crates.io crate agent-rex 0.0.0-nightly.20260308 already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b8e88e5ddf5521a9f43ee3f62a702388c713e4bb" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+b8e88e5ddf5521a9f43ee3f62a702388c713e4bb" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 1cdcbe176e0f2bab951d25ff7eb804a7a6b336ceb8c977a6b50a94f415d79281
[INFO] running `Command { std: "docker" "start" "-a" "1cdcbe176e0f2bab951d25ff7eb804a7a6b336ceb8c977a6b50a94f415d79281", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "1cdcbe176e0f2bab951d25ff7eb804a7a6b336ceb8c977a6b50a94f415d79281", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "1cdcbe176e0f2bab951d25ff7eb804a7a6b336ceb8c977a6b50a94f415d79281", kill_on_drop: false }`
[INFO] [stdout] 1cdcbe176e0f2bab951d25ff7eb804a7a6b336ceb8c977a6b50a94f415d79281
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+b8e88e5ddf5521a9f43ee3f62a702388c713e4bb" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] a1f0e7b29f9fa1a2e849f4d5767d343938f97a4a7eaf21777da39a9f85663dd3
[INFO] running `Command { std: "docker" "start" "-a" "a1f0e7b29f9fa1a2e849f4d5767d343938f97a4a7eaf21777da39a9f85663dd3", kill_on_drop: false }`
[INFO] [stderr]    Compiling crossbeam-utils v0.8.21
[INFO] [stderr]    Compiling futures-sink v0.3.32
[INFO] [stderr]    Compiling futures-io v0.3.32
[INFO] [stderr]    Compiling syn v2.0.117
[INFO] [stderr]    Compiling futures-channel v0.3.32
[INFO] [stderr]    Compiling concurrent-queue v2.5.0
[INFO] [stderr]    Compiling event-listener v5.4.1
[INFO] [stderr]    Compiling event-listener-strategy v0.5.4
[INFO] [stderr]    Compiling async-lock v3.4.2
[INFO] [stderr]    Compiling futures-macro v0.3.32
[INFO] [stderr]    Compiling async-stream-impl v0.3.6
[INFO] [stderr]    Compiling async-stream v0.3.6
[INFO] [stderr]    Compiling futures-util v0.3.32
[INFO] [stderr]    Compiling futures-executor v0.3.32
[INFO] [stderr]    Compiling futures v0.3.32
[INFO] [stderr]    Compiling agent-rex v0.0.0-nightly.20260308 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `pending`
[INFO] [stdout]   --> src/lib.rs:21:27
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::future::{Future, pending};
[INFO] [stdout]    |                           ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused macro definition: `pipe`
[INFO] [stdout]    --> src/lib.rs:615:14
[INFO] [stdout]     |
[INFO] [stdout] 615 | macro_rules! pipe {
[INFO] [stdout]     |              ^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_macros)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `select`
[INFO] [stdout]     --> src/lib.rs:3311:27
[INFO] [stdout]      |
[INFO] [stdout] 3311 |     use futures::future::{select, Either};
[INFO] [stdout]      |                           ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `pending` is never read
[INFO] [stdout]     --> src/lib.rs:1512:34
[INFO] [stdout]      |
[INFO] [stdout] 1512 |     let mut pending: Option<T> = None;
[INFO] [stdout]      |                                  ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 1530 |             pending = Some(v);
[INFO] [stdout]      |             ------- `pending` is overwritten here before the previous value is read
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `spawned` is never read
[INFO] [stdout]     --> src/lib.rs:2499:7
[INFO] [stdout]      |
[INFO] [stdout] 2499 |       spawned = true;
[INFO] [stdout]      |       ^^^^^^^^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]      = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `source`
[INFO] [stdout]     --> src/lib.rs:2671:33
[INFO] [stdout]      |
[INFO] [stdout] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stdout]      |                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_source`
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `duration`
[INFO] [stdout]     --> src/lib.rs:3255:12
[INFO] [stdout]      |
[INFO] [stdout] 3255 |   fn sleep(duration: Duration) -> Pin<Box<dyn Future<Output = ()> + Send>> {
[INFO] [stdout]      |            ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_duration`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `period`
[INFO] [stdout]     --> src/lib.rs:3262:15
[INFO] [stdout]      |
[INFO] [stdout] 3262 |   fn interval(period: Duration) -> Pin<Box<dyn futures::Stream<Item = ()> + Send>> {
[INFO] [stdout]      |               ^^^^^^ help: if this is intentional, prefix it with an underscore: `_period`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `error` is never read
[INFO] [stdout]     --> src/lib.rs:2555:3
[INFO] [stdout]      |
[INFO] [stdout] 2551 | struct ReplaySubjectInner<T> {
[INFO] [stdout]      |        ------------------ field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 2555 |   error: Option<Arc<dyn std::error::Error + Send + Sync>>,
[INFO] [stdout]      |   ^^^^^
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Replay` is never constructed
[INFO] [stdout]     --> src/lib.rs:2657:8
[INFO] [stdout]      |
[INFO] [stdout] 2657 | struct Replay<T> {
[INFO] [stdout]      |        ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ReplayInner` is never constructed
[INFO] [stdout]     --> src/lib.rs:2661:8
[INFO] [stdout]      |
[INFO] [stdout] 2661 | struct ReplayInner<T> {
[INFO] [stdout]      |        ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `subscribe`, and `start_source` are never used
[INFO] [stdout]     --> src/lib.rs:2671:6
[INFO] [stdout]      |
[INFO] [stdout] 2670 | impl<T: Clone + Send + 'static> Replay<T> {
[INFO] [stdout]      | ----------------------------------------- associated items in this implementation
[INFO] [stdout] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stdout]      |      ^^^
[INFO] [stdout] ...
[INFO] [stdout] 2687 |   fn subscribe(&self) -> impl futures::Stream<Item = T> {
[INFO] [stdout]      |      ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 2715 |   async fn start_source<S>(&self, mut source: S)
[INFO] [stdout]      |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay` is never used
[INFO] [stdout]     --> src/lib.rs:2744:4
[INFO] [stdout]      |
[INFO] [stdout] 2744 | fn replay<T, S>(buffer_size: usize, source: S) -> impl futures::Stream<Item = T>
[INFO] [stdout]      |    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `share` is never used
[INFO] [stdout]     --> src/lib.rs:2776:4
[INFO] [stdout]      |
[INFO] [stdout] 2776 | fn share<T, S>(source: S) -> impl futures::Stream<Item = T>
[INFO] [stdout]      |    ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_factory` is never used
[INFO] [stdout]     --> src/lib.rs:2816:4
[INFO] [stdout]      |
[INFO] [stdout] 2816 | fn replay_factory<T, S>(
[INFO] [stdout]      |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_stream` is never used
[INFO] [stdout]     --> src/lib.rs:2946:4
[INFO] [stdout]      |
[INFO] [stdout] 2946 | fn replay_stream<T, S>(
[INFO] [stdout]      |    ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_stream_example` is never used
[INFO] [stdout]     --> src/lib.rs:2963:10
[INFO] [stdout]      |
[INFO] [stdout] 2963 | async fn replay_stream_example() {
[INFO] [stdout]      |          ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 10.18s
[INFO] running `Command { std: "docker" "inspect" "a1f0e7b29f9fa1a2e849f4d5767d343938f97a4a7eaf21777da39a9f85663dd3", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "a1f0e7b29f9fa1a2e849f4d5767d343938f97a4a7eaf21777da39a9f85663dd3", kill_on_drop: false }`
[INFO] [stdout] a1f0e7b29f9fa1a2e849f4d5767d343938f97a4a7eaf21777da39a9f85663dd3
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+b8e88e5ddf5521a9f43ee3f62a702388c713e4bb" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 760e6a1d6c3eced867ac5aa57109d47906b41b6da8add75b5927e09c7be874cf
[INFO] running `Command { std: "docker" "start" "-a" "760e6a1d6c3eced867ac5aa57109d47906b41b6da8add75b5927e09c7be874cf", kill_on_drop: false }`
[INFO] [stderr]    Compiling tokio-macros v2.6.1
[INFO] [stdout] warning: unused import: `pending`
[INFO] [stdout]   --> src/lib.rs:21:27
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::future::{Future, pending};
[INFO] [stdout]    |                           ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused macro definition: `pipe`
[INFO] [stdout]    --> src/lib.rs:615:14
[INFO] [stdout]     |
[INFO] [stdout] 615 | macro_rules! pipe {
[INFO] [stdout]     |              ^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_macros)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `select`
[INFO] [stdout]     --> src/lib.rs:3311:27
[INFO] [stdout]      |
[INFO] [stdout] 3311 |     use futures::future::{select, Either};
[INFO] [stdout]      |                           ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `pending` is never read
[INFO] [stdout]     --> src/lib.rs:1512:34
[INFO] [stdout]      |
[INFO] [stdout] 1512 |     let mut pending: Option<T> = None;
[INFO] [stdout]      |                                  ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 1530 |             pending = Some(v);
[INFO] [stdout]      |             ------- `pending` is overwritten here before the previous value is read
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `spawned` is never read
[INFO] [stdout]     --> src/lib.rs:2499:7
[INFO] [stdout]      |
[INFO] [stdout] 2499 |       spawned = true;
[INFO] [stdout]      |       ^^^^^^^^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]      = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `source`
[INFO] [stdout]     --> src/lib.rs:2671:33
[INFO] [stdout]      |
[INFO] [stdout] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stdout]      |                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_source`
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `duration`
[INFO] [stdout]     --> src/lib.rs:3255:12
[INFO] [stdout]      |
[INFO] [stdout] 3255 |   fn sleep(duration: Duration) -> Pin<Box<dyn Future<Output = ()> + Send>> {
[INFO] [stdout]      |            ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_duration`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `period`
[INFO] [stdout]     --> src/lib.rs:3262:15
[INFO] [stdout]      |
[INFO] [stdout] 3262 |   fn interval(period: Duration) -> Pin<Box<dyn futures::Stream<Item = ()> + Send>> {
[INFO] [stdout]      |               ^^^^^^ help: if this is intentional, prefix it with an underscore: `_period`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `error` is never read
[INFO] [stdout]     --> src/lib.rs:2555:3
[INFO] [stdout]      |
[INFO] [stdout] 2551 | struct ReplaySubjectInner<T> {
[INFO] [stdout]      |        ------------------ field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 2555 |   error: Option<Arc<dyn std::error::Error + Send + Sync>>,
[INFO] [stdout]      |   ^^^^^
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `Replay` is never constructed
[INFO] [stdout]     --> src/lib.rs:2657:8
[INFO] [stdout]      |
[INFO] [stdout] 2657 | struct Replay<T> {
[INFO] [stdout]      |        ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: struct `ReplayInner` is never constructed
[INFO] [stdout]     --> src/lib.rs:2661:8
[INFO] [stdout]      |
[INFO] [stdout] 2661 | struct ReplayInner<T> {
[INFO] [stdout]      |        ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated items `new`, `subscribe`, and `start_source` are never used
[INFO] [stdout]     --> src/lib.rs:2671:6
[INFO] [stdout]      |
[INFO] [stdout] 2670 | impl<T: Clone + Send + 'static> Replay<T> {
[INFO] [stdout]      | ----------------------------------------- associated items in this implementation
[INFO] [stdout] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stdout]      |      ^^^
[INFO] [stdout] ...
[INFO] [stdout] 2687 |   fn subscribe(&self) -> impl futures::Stream<Item = T> {
[INFO] [stdout]      |      ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 2715 |   async fn start_source<S>(&self, mut source: S)
[INFO] [stdout]      |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay` is never used
[INFO] [stdout]     --> src/lib.rs:2744:4
[INFO] [stdout]      |
[INFO] [stdout] 2744 | fn replay<T, S>(buffer_size: usize, source: S) -> impl futures::Stream<Item = T>
[INFO] [stdout]      |    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `share` is never used
[INFO] [stdout]     --> src/lib.rs:2776:4
[INFO] [stdout]      |
[INFO] [stdout] 2776 | fn share<T, S>(source: S) -> impl futures::Stream<Item = T>
[INFO] [stdout]      |    ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_factory` is never used
[INFO] [stdout]     --> src/lib.rs:2816:4
[INFO] [stdout]      |
[INFO] [stdout] 2816 | fn replay_factory<T, S>(
[INFO] [stdout]      |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_stream` is never used
[INFO] [stdout]     --> src/lib.rs:2946:4
[INFO] [stdout]      |
[INFO] [stdout] 2946 | fn replay_stream<T, S>(
[INFO] [stdout]      |    ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_stream_example` is never used
[INFO] [stdout]     --> src/lib.rs:2963:10
[INFO] [stdout]      |
[INFO] [stdout] 2963 | async fn replay_stream_example() {
[INFO] [stdout]      |          ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]    Compiling tokio v1.50.0
[INFO] [stderr]    Compiling agent-rex v0.0.0-nightly.20260308 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `pending`
[INFO] [stdout]   --> src/lib.rs:21:27
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::future::{Future, pending};
[INFO] [stdout]    |                           ^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused macro definition: `pipe`
[INFO] [stdout]    --> src/lib.rs:615:14
[INFO] [stdout]     |
[INFO] [stdout] 615 | macro_rules! pipe {
[INFO] [stdout]     |              ^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_macros)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `select`
[INFO] [stdout]     --> src/lib.rs:3311:27
[INFO] [stdout]      |
[INFO] [stdout] 3311 |     use futures::future::{select, Either};
[INFO] [stdout]      |                           ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `streams`
[INFO] [stdout]    --> src/lib.rs:559:9
[INFO] [stdout]     |
[INFO] [stdout] 559 |     let streams = vec![
[INFO] [stdout]     |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_streams`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> src/lib.rs:912:9
[INFO] [stdout]     |
[INFO] [stdout] 912 |     let mut stream = continue_with(second, first);
[INFO] [stdout]     |         ----^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `pending` is never read
[INFO] [stdout]     --> src/lib.rs:1512:34
[INFO] [stdout]      |
[INFO] [stdout] 1512 |     let mut pending: Option<T> = None;
[INFO] [stdout]      |                                  ^^^^ this value is reassigned later and never used
[INFO] [stdout] ...
[INFO] [stdout] 1530 |             pending = Some(v);
[INFO] [stdout]      |             ------- `pending` is overwritten here before the previous value is read
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: value assigned to `spawned` is never read
[INFO] [stdout]     --> src/lib.rs:2499:7
[INFO] [stdout]      |
[INFO] [stdout] 2499 |       spawned = true;
[INFO] [stdout]      |       ^^^^^^^^^^^^^^
[INFO] [stdout]      |
[INFO] [stdout]      = help: maybe it is overwritten before being read?
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `source`
[INFO] [stdout]     --> src/lib.rs:2671:33
[INFO] [stdout]      |
[INFO] [stdout] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stdout]      |                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_source`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `replay`
[INFO] [stdout]     --> src/lib.rs:2765:9
[INFO] [stdout]      |
[INFO] [stdout] 2765 |     let replay = Replay::new(2, source);
[INFO] [stdout]      |         ^^^^^^ help: if this is intentional, prefix it with an underscore: `_replay`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `duration`
[INFO] [stdout]     --> src/lib.rs:3255:12
[INFO] [stdout]      |
[INFO] [stdout] 3255 |   fn sleep(duration: Duration) -> Pin<Box<dyn Future<Output = ()> + Send>> {
[INFO] [stdout]      |            ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_duration`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `period`
[INFO] [stdout]     --> src/lib.rs:3262:15
[INFO] [stdout]      |
[INFO] [stdout] 3262 |   fn interval(period: Duration) -> Pin<Box<dyn futures::Stream<Item = ()> + Send>> {
[INFO] [stdout]      |               ^^^^^^ help: if this is intentional, prefix it with an underscore: `_period`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `error` is never read
[INFO] [stdout]     --> src/lib.rs:2555:3
[INFO] [stdout]      |
[INFO] [stdout] 2551 | struct ReplaySubjectInner<T> {
[INFO] [stdout]      |        ------------------ field in this struct
[INFO] [stdout] ...
[INFO] [stdout] 2555 |   error: Option<Arc<dyn std::error::Error + Send + Sync>>,
[INFO] [stdout]      |   ^^^^^
[INFO] [stdout]      |
[INFO] [stdout]      = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field `inner` is never read
[INFO] [stdout]     --> src/lib.rs:2658:3
[INFO] [stdout]      |
[INFO] [stdout] 2657 | struct Replay<T> {
[INFO] [stdout]      |        ------ field in this struct
[INFO] [stdout] 2658 |   inner: Arc<Mutex<ReplayInner<T>>>,
[INFO] [stdout]      |   ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: fields `buffer`, `buffer_size`, `completed`, `error`, `source_started`, and `subscribers` are never read
[INFO] [stdout]     --> src/lib.rs:2662:3
[INFO] [stdout]      |
[INFO] [stdout] 2661 | struct ReplayInner<T> {
[INFO] [stdout]      |        ----------- fields in this struct
[INFO] [stdout] 2662 |   buffer: Vec<T>,
[INFO] [stdout]      |   ^^^^^^
[INFO] [stdout] 2663 |   buffer_size: usize,
[INFO] [stdout]      |   ^^^^^^^^^^^
[INFO] [stdout] 2664 |   completed: bool,
[INFO] [stdout]      |   ^^^^^^^^^
[INFO] [stdout] 2665 |   error: Option<Arc<dyn std::error::Error + Send + Sync>>,
[INFO] [stdout]      |   ^^^^^
[INFO] [stdout] 2666 |   source_started: bool,
[INFO] [stdout]      |   ^^^^^^^^^^^^^^
[INFO] [stdout] 2667 |   subscribers: Vec<futures::channel::mpsc::UnboundedSender<Result<T, Arc<dyn std::error::Error + Send + Sync>>>>,
[INFO] [stdout]      |   ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: methods `subscribe` and `start_source` are never used
[INFO] [stdout]     --> src/lib.rs:2687:6
[INFO] [stdout]      |
[INFO] [stdout] 2670 | impl<T: Clone + Send + 'static> Replay<T> {
[INFO] [stdout]      | ----------------------------------------- methods in this implementation
[INFO] [stdout] ...
[INFO] [stdout] 2687 |   fn subscribe(&self) -> impl futures::Stream<Item = T> {
[INFO] [stdout]      |      ^^^^^^^^^
[INFO] [stdout] ...
[INFO] [stdout] 2715 |   async fn start_source<S>(&self, mut source: S)
[INFO] [stdout]      |            ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_factory` is never used
[INFO] [stdout]     --> src/lib.rs:2816:4
[INFO] [stdout]      |
[INFO] [stdout] 2816 | fn replay_factory<T, S>(
[INFO] [stdout]      |    ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_stream` is never used
[INFO] [stdout]     --> src/lib.rs:2946:4
[INFO] [stdout]      |
[INFO] [stdout] 2946 | fn replay_stream<T, S>(
[INFO] [stdout]      |    ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function `replay_stream_example` is never used
[INFO] [stdout]     --> src/lib.rs:2963:10
[INFO] [stdout]      |
[INFO] [stdout] 2963 | async fn replay_stream_example() {
[INFO] [stdout]      |          ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 7.68s
[INFO] running `Command { std: "docker" "inspect" "760e6a1d6c3eced867ac5aa57109d47906b41b6da8add75b5927e09c7be874cf", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "760e6a1d6c3eced867ac5aa57109d47906b41b6da8add75b5927e09c7be874cf", kill_on_drop: false }`
[INFO] [stdout] 760e6a1d6c3eced867ac5aa57109d47906b41b6da8add75b5927e09c7be874cf
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+b8e88e5ddf5521a9f43ee3f62a702388c713e4bb" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] a8f4aca41c7540060ef46f2644190f3fcd9a8a27b22091a6c82563ee8f9079cc
[INFO] running `Command { std: "docker" "start" "-a" "a8f4aca41c7540060ef46f2644190f3fcd9a8a27b22091a6c82563ee8f9079cc", kill_on_drop: false }`
[INFO] [stderr] warning: unused import: `pending`
[INFO] [stderr]   --> src/lib.rs:21:27
[INFO] [stderr]    |
[INFO] [stderr] 21 | use std::future::{Future, pending};
[INFO] [stderr]    |                           ^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused macro definition: `pipe`
[INFO] [stderr]    --> src/lib.rs:615:14
[INFO] [stderr]     |
[INFO] [stderr] 615 | macro_rules! pipe {
[INFO] [stderr]     |              ^^^^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_macros)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `select`
[INFO] [stderr]     --> src/lib.rs:3311:27
[INFO] [stderr]      |
[INFO] [stderr] 3311 |     use futures::future::{select, Either};
[INFO] [stderr]      |                           ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `pending` is never read
[INFO] [stderr]     --> src/lib.rs:1512:34
[INFO] [stderr]      |
[INFO] [stderr] 1512 |     let mut pending: Option<T> = None;
[INFO] [stderr]      |                                  ^^^^ this value is reassigned later and never used
[INFO] [stderr] ...
[INFO] [stderr] 1530 |             pending = Some(v);
[INFO] [stderr]      |             ------- `pending` is overwritten here before the previous value is read
[INFO] [stderr]      |
[INFO] [stderr]      = note: `#[warn(unused_assignments)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: value assigned to `spawned` is never read
[INFO] [stderr]     --> src/lib.rs:2499:7
[INFO] [stderr]      |
[INFO] [stderr] 2499 |       spawned = true;
[INFO] [stderr]      |       ^^^^^^^^^^^^^^
[INFO] [stderr]      |
[INFO] [stderr]      = help: maybe it is overwritten before being read?
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `source`
[INFO] [stderr]     --> src/lib.rs:2671:33
[INFO] [stderr]      |
[INFO] [stderr] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stderr]      |                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_source`
[INFO] [stderr]      |
[INFO] [stderr]      = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `duration`
[INFO] [stderr]     --> src/lib.rs:3255:12
[INFO] [stderr]      |
[INFO] [stderr] 3255 |   fn sleep(duration: Duration) -> Pin<Box<dyn Future<Output = ()> + Send>> {
[INFO] [stderr]      |            ^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_duration`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `period`
[INFO] [stderr]     --> src/lib.rs:3262:15
[INFO] [stderr]      |
[INFO] [stderr] 3262 |   fn interval(period: Duration) -> Pin<Box<dyn futures::Stream<Item = ()> + Send>> {
[INFO] [stderr]      |               ^^^^^^ help: if this is intentional, prefix it with an underscore: `_period`
[INFO] [stderr] 
[INFO] [stderr] warning: field `error` is never read
[INFO] [stderr]     --> src/lib.rs:2555:3
[INFO] [stderr]      |
[INFO] [stderr] 2551 | struct ReplaySubjectInner<T> {
[INFO] [stderr]      |        ------------------ field in this struct
[INFO] [stderr] ...
[INFO] [stderr] 2555 |   error: Option<Arc<dyn std::error::Error + Send + Sync>>,
[INFO] [stderr]      |   ^^^^^
[INFO] [stderr]      |
[INFO] [stderr]      = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: struct `Replay` is never constructed
[INFO] [stderr]     --> src/lib.rs:2657:8
[INFO] [stderr]      |
[INFO] [stderr] 2657 | struct Replay<T> {
[INFO] [stderr]      |        ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: struct `ReplayInner` is never constructed
[INFO] [stderr]     --> src/lib.rs:2661:8
[INFO] [stderr]      |
[INFO] [stderr] 2661 | struct ReplayInner<T> {
[INFO] [stderr]      |        ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: associated items `new`, `subscribe`, and `start_source` are never used
[INFO] [stderr]     --> src/lib.rs:2671:6
[INFO] [stderr]      |
[INFO] [stderr] 2670 | impl<T: Clone + Send + 'static> Replay<T> {
[INFO] [stderr]      | ----------------------------------------- associated items in this implementation
[INFO] [stderr] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stderr]      |      ^^^
[INFO] [stderr] ...
[INFO] [stderr] 2687 |   fn subscribe(&self) -> impl futures::Stream<Item = T> {
[INFO] [stderr]      |      ^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 2715 |   async fn start_source<S>(&self, mut source: S)
[INFO] [stderr]      |            ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `replay` is never used
[INFO] [stderr]     --> src/lib.rs:2744:4
[INFO] [stderr]      |
[INFO] [stderr] 2744 | fn replay<T, S>(buffer_size: usize, source: S) -> impl futures::Stream<Item = T>
[INFO] [stderr]      |    ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `share` is never used
[INFO] [stderr]     --> src/lib.rs:2776:4
[INFO] [stderr]      |
[INFO] [stderr] 2776 | fn share<T, S>(source: S) -> impl futures::Stream<Item = T>
[INFO] [stderr]      |    ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `replay_factory` is never used
[INFO] [stderr]     --> src/lib.rs:2816:4
[INFO] [stderr]      |
[INFO] [stderr] 2816 | fn replay_factory<T, S>(
[INFO] [stderr]      |    ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `replay_stream` is never used
[INFO] [stderr]     --> src/lib.rs:2946:4
[INFO] [stderr]      |
[INFO] [stderr] 2946 | fn replay_stream<T, S>(
[INFO] [stderr]      |    ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: function `replay_stream_example` is never used
[INFO] [stderr]     --> src/lib.rs:2963:10
[INFO] [stderr]      |
[INFO] [stderr] 2963 | async fn replay_stream_example() {
[INFO] [stderr]      |          ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `streams`
[INFO] [stderr]    --> src/lib.rs:559:9
[INFO] [stderr]     |
[INFO] [stderr] 559 |     let streams = vec![
[INFO] [stderr]     |         ^^^^^^^ help: if this is intentional, prefix it with an underscore: `_streams`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> src/lib.rs:912:9
[INFO] [stderr]     |
[INFO] [stderr] 912 |     let mut stream = continue_with(second, first);
[INFO] [stderr]     |         ----^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `source`
[INFO] [stderr]     --> src/lib.rs:2671:33
[INFO] [stderr]      |
[INFO] [stderr] 2671 |   fn new<S>(buffer_size: usize, source: S) -> Self
[INFO] [stderr]      |                                 ^^^^^^ help: if this is intentional, prefix it with an underscore: `_source`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `replay`
[INFO] [stderr]     --> src/lib.rs:2765:9
[INFO] [stderr]      |
[INFO] [stderr] 2765 |     let replay = Replay::new(2, source);
[INFO] [stderr]      |         ^^^^^^ help: if this is intentional, prefix it with an underscore: `_replay`
[INFO] [stderr] 
[INFO] [stderr] warning: field `inner` is never read
[INFO] [stderr]     --> src/lib.rs:2658:3
[INFO] [stderr]      |
[INFO] [stderr] 2657 | struct Replay<T> {
[INFO] [stderr]      |        ------ field in this struct
[INFO] [stderr] 2658 |   inner: Arc<Mutex<ReplayInner<T>>>,
[INFO] [stderr]      |   ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: fields `buffer`, `buffer_size`, `completed`, `error`, `source_started`, and `subscribers` are never read
[INFO] [stderr]     --> src/lib.rs:2662:3
[INFO] [stderr]      |
[INFO] [stderr] 2661 | struct ReplayInner<T> {
[INFO] [stderr]      |        ----------- fields in this struct
[INFO] [stderr] 2662 |   buffer: Vec<T>,
[INFO] [stderr]      |   ^^^^^^
[INFO] [stderr] 2663 |   buffer_size: usize,
[INFO] [stderr]      |   ^^^^^^^^^^^
[INFO] [stderr] 2664 |   completed: bool,
[INFO] [stderr]      |   ^^^^^^^^^
[INFO] [stderr] 2665 |   error: Option<Arc<dyn std::error::Error + Send + Sync>>,
[INFO] [stderr]      |   ^^^^^
[INFO] [stderr] 2666 |   source_started: bool,
[INFO] [stderr]      |   ^^^^^^^^^^^^^^
[INFO] [stderr] 2667 |   subscribers: Vec<futures::channel::mpsc::UnboundedSender<Result<T, Arc<dyn std::error::Error + Send + Sync>>>>,
[INFO] [stderr]      |   ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: methods `subscribe` and `start_source` are never used
[INFO] [stderr]     --> src/lib.rs:2687:6
[INFO] [stderr]      |
[INFO] [stderr] 2670 | impl<T: Clone + Send + 'static> Replay<T> {
[INFO] [stderr]      | ----------------------------------------- methods in this implementation
[INFO] [stderr] ...
[INFO] [stderr] 2687 |   fn subscribe(&self) -> impl futures::Stream<Item = T> {
[INFO] [stderr]      |      ^^^^^^^^^
[INFO] [stderr] ...
[INFO] [stderr] 2715 |   async fn start_source<S>(&self, mut source: S)
[INFO] [stderr]      |            ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: `agent-rex` (lib) generated 17 warnings (run `cargo fix --lib -p agent-rex` to apply 5 suggestions)
[INFO] [stderr] warning: `agent-rex` (lib test) generated 18 warnings (11 duplicates) (run `cargo fix --lib -p agent-rex --tests` to apply 4 suggestions)
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.12s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/agent_rex-dbbd729d15ac6e3e)
[INFO] [stdout] 
[INFO] [stdout] running 89 tests
[INFO] [stdout] test apply_latest_tests::test_apply_latest ... ok
[INFO] [stdout] test await_tap_tests::test_await_tap_executes_side_effect ... ok
[INFO] [stdout] test buffer_tests::test_buffer_exact_multiple ... ok
[INFO] [stdout] test concat_tests::test_concat_vec_of_streams ... ok
[INFO] [stdout] test constant_tests::test_constant_empty_stream ... ok
[INFO] [stdout] test concat_tests::test_concat_with_empty_first ... ok
[INFO] [stdout] test buffer_tests::test_buffer ... ok
[INFO] [stdout] test concat_all_tests::test_concat_all_flattens ... ok
[INFO] [stdout] test continue_with_tests::test_continue_with_appends ... ok
[INFO] [stdout] test constant_tests::test_constant_replaces_all_values ... ok
[INFO] [stdout] test delay_tests::test_delay_empty_stream ... ok
[INFO] [stdout] test filter_tests::test_filter_keeps_matching ... ok
[INFO] [stdout] test from_iter_tests::test_from_iter_with_range ... ok
[INFO] [stdout] test concat_map_tests::test_concat_map_sequential ... ok
[INFO] [stdout] test from_future_tests::test_from_future_emits_resolved_value ... ok
[INFO] [stdout] test concat_tests::test_concat_joins_streams ... ok
[INFO] [stdout] test iterate_tests::test_iterate_with_addition ... ok
[INFO] [stdout] test from_iter_tests::test_from_iter_handles_empty ... ok
[INFO] [stdout] test iterate_tests::test_iterate_with_strings ... ok
[INFO] [stdout] test just_tests::test_just_with_string ... ok
[INFO] [stdout] test filter_tests::test_filter_even_numbers ... ok
[INFO] [stdout] test just_tests::test_just_emits_single_value ... ok
[INFO] [stdout] test iterate_tests::test_iterate_generates_sequence ... ok
[INFO] [stdout] test buffer_tests::test_buffer_empty ... ok
[INFO] [stdout] test just_tests::test_of_alias ... ok
[INFO] [stdout] test chain_tests::test_chain_flattens ... ok
[INFO] [stdout] test map_tests::test_map_transforms_values ... ok
[INFO] [stdout] test from_iter_tests::test_from_iter_emits_all_values ... ok
[INFO] [stdout] test filter_tests::test_filter_empty_result ... ok
[INFO] [stdout] test from_future_tests::test_from_future_with_async_computation ... ok
[INFO] [stdout] test merge_tests::test_merge_all ... ok
[INFO] [stdout] test recover_with_stream_tests::test_recover_with_stream_success ... ok
[INFO] [stdout] test map_tests::test_map_with_type_change ... ok
[INFO] [stdout] test recover_with_tests::test_recover_with_error ... ok
[INFO] [stdout] test merge_tests::test_merge ... ok
[INFO] [stdout] test latest2_tests::test_latest2_combines ... ok
[INFO] [stdout] test recover_with_tests::test_recover_with_no_error ... ok
[INFO] [stdout] test map_tests::test_map_empty_stream ... ok
[INFO] [stdout] test replay_subject_tests::test_replay_subject_buffer ... ok
[INFO] [stdout] test recover_with_stream_tests::test_recover_with_stream_uses_alternative ... ok
[INFO] [stdout] test retry_tests::test_retry_with_eventual_success ... ok
[INFO] [stdout] test scan_tests::test_scan_accumulates_with_seed ... ok
[INFO] [stdout] test replay_tests::test_replay_buffered ... ok
[INFO] [stdout] test retry_tests::test_retry_with_success ... ok
[INFO] [stdout] test empty_tests::test_empty_completes_immediately ... ok
[INFO] [stdout] test replay_subject_tests::test_replay_subject_unlimited ... ok
[INFO] [stdout] test skip_tests::test_skip_first_n ... ok
[INFO] [stdout] test replay_subject_tests::test_replay_subject_empty ... ok
[INFO] [stdout] test skip_tests::test_skip_more_than_available ... ok
[INFO] [stdout] test continue_with_tests::test_continue_with_lazy ... ok
[INFO] [stdout] test skip_tests::test_skip_zero ... ok
[INFO] [stdout] test skip_repeats_tests::test_skip_repeats_with_custom_eq ... ok
[INFO] [stdout] test empty_tests::test_empty_yields_nothing ... ok
[INFO] [stdout] test scan_tests::test_scan_empty_stream ... ok
[INFO] [stdout] test scan_tests::test_scan_product ... ok
[INFO] [stdout] test skip_while_tests::test_skip_while_all_fail ... ok
[INFO] [stdout] test skip_while_tests::test_skip_while ... ok
[INFO] [stdout] test share_tests::test_share_basic ... ok
[INFO] [stdout] test never_tests::test_never_does_not_complete ... ok
[INFO] [stdout] test slice_tests::test_slice_beyond_length ... ok
[INFO] [stdout] test skip_while_tests::test_skip_while_all_pass ... ok
[INFO] [stdout] test slice_tests::test_slice_empty_range ... ok
[INFO] [stdout] test since_stream_tests::test_since_stream_waits ... ok
[INFO] [stdout] test skip_repeats_tests::test_skip_repeats ... ok
[INFO] [stdout] test take_while_tests::test_take_while ... ok
[INFO] [stdout] test take_tests::test_take_first_n ... ok
[INFO] [stdout] test take_while_tests::test_take_while_none_pass ... ok
[INFO] [stdout] test test_runtime_tests::test_multiple_timers ... ok
[INFO] [stdout] test switch_map_tests::test_switch_map_switches ... ok
[INFO] [stdout] test start_with_tests::test_start_with_prepends_value ... ok
[INFO] [stdout] test slice_tests::test_slice ... ok
[INFO] [stdout] test take_until_tests::test_take_until_never_matches ... ok
[INFO] [stdout] test take_tests::test_take_more_than_available ... ok
[INFO] [stdout] test test_runtime_tests::test_virtual_interval ... ok
[INFO] [stdout] test take_while_tests::test_take_while_all_pass ... ok
[INFO] [stdout] test start_with_tests::test_start_with_on_empty_stream ... ok
[INFO] [stdout] test take_until_tests::test_take_until_first_matches ... ok
[INFO] [stdout] test throw_error_tests::test_throw_error_emits_error ... ok
[INFO] [stdout] test unfold_tests::test_unfold_generates_values ... ok
[INFO] [stdout] test unfold_tests::test_unfold_stops_immediately_when_done ... ok
[INFO] [stdout] test until_stream_tests::test_until_stream_stops ... ok
[INFO] [stdout] test unfold_tests::test_unfold_with_different_types ... ok
[INFO] [stdout] test take_tests::test_take_zero ... ok
[INFO] [stdout] test take_until_tests::test_take_until ... ok
[INFO] [stdout] test test_runtime_tests::test_virtual_sleep ... ok
[INFO] [stdout] test throttle_tests::test_throttle_empty ... ok
[INFO] [stdout] test throttle_tests::test_throttle_trailing ... ok
[INFO] [stdout] test throttle_tests::test_throttle_leading ... ok
[INFO] [stdout] test delay_tests::test_delay_with ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 89 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.07s
[INFO] [stdout] 
[INFO] [stderr]    Doc-tests agent_rex
[INFO] [stdout] 
[INFO] [stdout] running 13 tests
[INFO] [stdout] test src/lib.rs - filter (line 1003) ... ignored
[INFO] [stdout] test src/lib.rs - map (line 636) ... ignored
[INFO] [stdout] test src/lib.rs - map (line 641) ... ignored
[INFO] [stdout] test src/lib.rs - merge (line 1986) ... ignored
[INFO] [stdout] test src/lib.rs - merge_all (line 1996) ... ignored
[INFO] [stdout] test src/lib.rs - skip (line 1184) ... ignored
[INFO] [stdout] test src/lib.rs - skip_while (line 1331) ... ignored
[INFO] [stdout] test src/lib.rs - take (line 1128) ... ignored
[INFO] [stdout] test src/lib.rs - take_while (line 1279) ... ignored
[INFO] [stdout] test src/lib.rs - empty (line 312) ... ok
[INFO] [stdout] test src/lib.rs - TestRuntime (line 2997) ... ok
[INFO] [stdout] test src/lib.rs - never (line 342) ... ok
[INFO] [stdout] test src/lib.rs - from_iter (line 223) ... ok
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 4 passed; 0 failed; 9 ignored; 0 measured; 0 filtered out; finished in 0.45s
[INFO] [stdout] 
[INFO] running `Command { std: "docker" "inspect" "a8f4aca41c7540060ef46f2644190f3fcd9a8a27b22091a6c82563ee8f9079cc", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "a8f4aca41c7540060ef46f2644190f3fcd9a8a27b22091a6c82563ee8f9079cc", kill_on_drop: false }`
[INFO] [stdout] a8f4aca41c7540060ef46f2644190f3fcd9a8a27b22091a6c82563ee8f9079cc
